package com.pengheng.service;

import com.pengheng.bean.WaterSensor;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;

/**
 * 定义交通流量计算接口
 */
public interface ITrafficIndicatorAlgorithm {

    void algorithm(SingleOutputStreamOperator<WaterSensor> singleOutputStreamOperator) throws Exception;
}
